package com.my.conf;

import org.apache.flink.streaming.connectors.redis.common.config.FlinkJedisClusterConfig;

import java.net.InetSocketAddress;
import java.util.HashSet;

public class MyRedisCluster {

    public static FlinkJedisClusterConfig getConf(){
        HashSet<InetSocketAddress> addresses = new HashSet<>();
        addresses.add(new InetSocketAddress("192.168.80.105",6380));
        addresses.add(new InetSocketAddress("192.168.80.105",6381));
        addresses.add(new InetSocketAddress("192.168.80.105",6382));
        FlinkJedisClusterConfig conf = new FlinkJedisClusterConfig.Builder().setNodes(addresses).setPassword("root").build();
        return conf;
    }
}
